package com.owen.spark.test

import org.apache.spark.{SparkConf, SparkContext}

object RddModify {
  def main(args: Array[String]): Unit = {
    var conf = new SparkConf()
    conf.setAppName("join").setMaster("local[*]")

    var sc = new SparkContext(conf)
    val data = Array(1, 2, 3, 4, 5)
    val dataModify = Array()
    sc.parallelize(data).map(_=>{
      dataModify+_
      dataModify+"6"
    })
    println(dataModify.length)
  }
}
